package org.vacoor.xqq.core.mod;

/**
 * 消息接收器
 * 异步接收消息并派发消息
 * <p/>
 * User: vacoor
 */
public interface MessageReceiver {

    void start();

    /**
     * 开始接收消息
     *
     * warn: 在接收消息前应该确保所有消息处理已经注册完毕, 否则消息可能不会被处理
     *
     * @param minInterval 接收消息最小间隔,毫秒
     */
    void start(int minInterval);

    /**
     * 停止接收消息
     */
    void stop();

}
